package mq

import (
	"github.com/lab-online/internal/lab/entity"
	"github.com/lab-online/pkg/mq"
)

type MQ struct {
	*mq.MessageQueue
}

type LabMQ interface {
	// ProduceExperiment 发布执行实验消息
	ProduceExperiment(entity.LabEntity) (entity.LabEntity, error)
}

func New(rabbitMQ *mq.MessageQueue) LabMQ {
	return &MQ{rabbitMQ}
}
